package org.budo.canal.message.handler;

import com.alibaba.otter.canal.protocol.ClientIdentity;
import com.alibaba.otter.canal.protocol.Message;

/**
 * @author limingwei
 */
public interface CanalMessageHandler {
    void handleMessage(Message message, ClientIdentity clientIdentity);
}